-
Notifications
You must be signed in to change notification settings - Fork 0
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
feat: processor service integration #22
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
nice! 🚀
apps/processor/README.md
Outdated
|
||
### ⚙️ Setting up env variables | ||
|
||
- Create `.env` file and copy paste `.env.example` content in there. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I would add: "or run the below command"
@@ -26,8 +21,8 @@ export class IpfsProvider implements IMetadataProvider { | |||
ipfsCid: string, | |||
validateContent?: z.ZodSchema<T>, | |||
): Promise<T | undefined> { | |||
if (!isValidCid(ipfsCid)) { | |||
throw new InvalidCidException(ipfsCid); | |||
if (ipfsCid === "" || !isValidCid(ipfsCid)) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
logging might be good here if just returning undefined
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
could be, i think here i'll leave the responsibility of logging to the caller
apps/processor/README.md
Outdated
| `DATABASE_URL` | PostgreSQL Data Layer database connection URL | N/A | Yes | | | ||
| `DATABASE_SCHEMA` | PostgreSQL Data Layer database schema name | chainDataSchema | Yes | | | ||
| `INDEXER_GRAPHQL_URL` | GraphQL endpoint for the indexer | N/A | Yes | | | ||
| `INDEXER_ADMIN_SECRET` | Admin secret for indexer authentication | N/A | Yes | | |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
we should change this, admin secret is just for admins, should be a way to generate some token for client auth
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
apps/processor/README.md
Outdated
| `INDEXER_ADMIN_SECRET` | Admin secret for indexer authentication | N/A | Yes | | | ||
| `IPFS_GATEWAYS_URL` | Array of IPFS gateway URLs | N/A | Yes | Multiple gateways for redundancy | | ||
| `COINGECKO_API_KEY` | API key for CoinGecko service | N/A | Yes | | | ||
| `COINGECKO_API_TYPE` | CoinGecko API tier (demo or pro) | N/A | Yes | | |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
lets use default pro
here
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
give me my Pro Key xd
apps/processor/src/index.ts
Outdated
let processor: ProcessorService; | ||
|
||
const main = async (): Promise<void> => { | ||
processor = new ProcessorService(environment); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
What about using Processing
instead of Processor
to avoid confusion with the event processors, if we modify this we should include modifying file names also
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
aaa okay makes sense, Processor was a more natural naming. the app folder should also be apps/processing
?
🤖 Linear
Closes GIT-74 GIT-75
Description
processor
app that integrates all the Core components of the processing pipeline and runs a single chain Orchestratorenvio
versionChecklist before requesting a review